
/**
* 上海中赢金融信息服务有限公司
* Copyright (c) 2017-2027 Chinazyjr,Inc.All Rights Reserved.
*/
package com.sys.kafka.config;

/**
 * <b>Description：</b> TODO <br/>
 * <b>ClassName：</b> ConsumerProperty <br/>
 * <b>@author：</b> mobing <br/>
 * <b>@date：</b> 2017年7月13日 下午4:01:47 <br/>
 * <b>@version: </b> <br/>
 */
public class KafkaConfig4Consumer {

    private String group_id;

    private boolean enable_auto_commit;

    private long auto_commit_interval_ms;

    private int session_timeout_ms;

    private String auto_offset_reset;

    private String key_serializer;

    private String value_serializer;


    /**
     * auto_offset_reset
     *
     * @return the auto_offset_reset
     */

    public String getAuto_offset_reset() {
        return auto_offset_reset;
    }

    /**
     * @param auto_offset_reset
     *            the auto_offset_reset to set
     */
    public void setAuto_offset_reset(String auto_offset_reset) {
        this.auto_offset_reset = auto_offset_reset;
    }

    /**
     * group_id
     *
     * @return the group_id
     */

    public String getGroup_id() {
        return group_id;
    }

    /**
     * @param group_id
     *            the group_id to set
     */
    public void setGroup_id(String group_id) {
        this.group_id = group_id;
    }

    /**
     * enable_auto_commit
     *
     * @return the enable_auto_commit
     */

    public boolean isEnable_auto_commit() {
        return enable_auto_commit;
    }

    /**
     * @param enable_auto_commit
     *            the enable_auto_commit to set
     */
    public void setEnable_auto_commit(boolean enable_auto_commit) {
        this.enable_auto_commit = enable_auto_commit;
    }

    /**
     * auto_commit_interval_ms
     *
     * @return the auto_commit_interval_ms
     */

    public long getAuto_commit_interval_ms() {
        return auto_commit_interval_ms;
    }

    /**
     * @param auto_commit_interval_ms
     *            the auto_commit_interval_ms to set
     */
    public void setAuto_commit_interval_ms(long auto_commit_interval_ms) {
        this.auto_commit_interval_ms = auto_commit_interval_ms;
    }

    /**
     * session_timeout_ms
     *
     * @return the session_timeout_ms
     */

    public int getSession_timeout_ms() {
        return session_timeout_ms;
    }

   

    /**
     * @param session_timeout_ms the session_timeout_ms to set
     */
    public void setSession_timeout_ms(int session_timeout_ms) {
        this.session_timeout_ms = session_timeout_ms;
    }

    /**
     * key_serializer
     *
     * @return the key_serializer
     */

    public String getKey_serializer() {
        return key_serializer;
    }

    /**
     * @param key_serializer
     *            the key_serializer to set
     */
    public void setKey_serializer(String key_serializer) {
        this.key_serializer = key_serializer;
    }

    /**
     * value_serializer
     *
     * @return the value_serializer
     */

    public String getValue_serializer() {
        return value_serializer;
    }

    /**
     * @param value_serializer
     *            the value_serializer to set
     */
    public void setValue_serializer(String value_serializer) {
        this.value_serializer = value_serializer;
    }


}
